package com.mxl.rabbitmq.consumer;

import com.alibaba.fastjson.JSON;
import com.mxl.rabbitmq.model.MessageBody;
import lombok.extern.slf4j.Slf4j;

/**
 * @author MXL
 * @date 2021/9/14 0014
 **/
//@Component
@Slf4j
public class DelayedReceiver {

    //@RabbitListener(queues = DelayedConfig.QUEUE_NAME_DELAYED)//监听的队列名称 TestDirectQueue
    public void process(MessageBody messageBody) {
        log.info("Dellayted-Receiver消费者收到消息  : {}", JSON.toJSONString(messageBody));
    }

}
